package com.wzz.canal.protobuf;

import org.apache.kafka.common.serialization.Serializer;

import java.util.Map;

public class ProtoBufSerializer implements Serializer<ProtoBufable> {

    @Override
    public void configure(Map<String, ?> map, boolean b) {

    }

    @Override
    public byte[] serialize(String s, ProtoBufable protoBufable) {
        return protoBufable.toByte();
    }

    @Override
    public void close() {

    }
}
